package com.gis.bigdata.spark02.core.framework.controller

import com.gis.bigdata.spark02.core.framework.common.TController
import com.gis.bigdata.spark02.core.framework.service.WordCountService
import org.apache.spark.rdd.RDD

/**
 * @author LnnuUser
 * @create 2022-10-07-下午9:39
 * 控制层
 */
class WordCountController extends TController{

  private val wordCountService: WordCountService = new WordCountService()

  // 调度
  def dispatch(): Unit = {

    val array: Array[(String, Int)] = wordCountService.dataAnalysis()
    array.foreach(println)
  }

}
